package cn.flying.cloud.task.core.controller;//package cn.flying.cloud.task.core.controller;
//
//import javax.annotation.Resource;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import cn.flying.cloud.base.common.vo.Rt;
//import cn.flying.cloud.task.core.model.JobInfo;
//import cn.flying.cloud.task.core.service.JobService;
//
//
///**
// * 定时任务配置信息 前端控制器
// *
// * @author: admin
// * @date: 2024-06-05 11:55:42
// * @version: 1.0
// */
//@RestController
//@RequestMapping("/manager/jobInfo")
//public class JobInfoController {
//    private final Logger logger = LoggerFactory.getLogger(this.getClass());
//
//    @Resource
//    private JobService jobService;
//
//    /**
//     * 新增任务
//     *
//     * @param job
//     * @return
//     */
//    @PostMapping("insertJob")
//    public Rt insertJob(@RequestBody JobInfo job) {
//        jobService.insertJob(job);
//        return Rt.success("新增任务成功！");
//    }
//
//    /**
//     * 删除任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @RequestMapping("deleteJob")
//    public Rt<JobInfo> deleteJob(@RequestBody JobInfo jobInfo) {
//        jobService.deleteJob(jobInfo.getJobName(), jobInfo.getJobGroup());
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】删除成功！");
//    }
//
//    /**
//     * 修改任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @PostMapping("updateJob")
//    public Rt<JobInfo> updateJob(@RequestBody JobInfo jobInfo) {
//        jobService.updateJob(jobInfo);
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】修改成功！");
//    }
//
//    /**
//     * 暂停任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @RequestMapping("pause")
//    public Rt<JobInfo> pauseJob(@RequestBody JobInfo jobInfo) {
//        jobService.pauseJob(jobInfo.getJobName(), jobInfo.getJobGroup());
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】暂停运行！");
//    }
//
//    /**
//     * 恢复任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @RequestMapping("resume")
//    public Rt<JobInfo> resumeJob(@RequestBody JobInfo jobInfo) {
//        jobService.resumeJob(jobInfo.getJobName(), jobInfo.getJobGroup());
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】恢复运行！");
//    }
//
//    /**
//     * 中断正在运行任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @RequestMapping("stop")
//    public Rt<JobInfo> interruptJob(@RequestBody JobInfo jobInfo) {
//        jobService.interruptJob(jobInfo.getJobName(), jobInfo.getJobGroup());
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】停止运行！");
//    }
//
//    /**
//     * 立即触发执行一次任务
//     *
//     * @param jobInfo
//     * @return
//     */
//    @RequestMapping("trigger")
//    public Rt<JobInfo> triggerJob(@RequestBody JobInfo jobInfo) {
//        jobService.triggerJob(jobInfo.getJobName(), jobInfo.getJobGroup());
//        return Rt.success("所属【" + jobInfo.getJobGroup() + "】任务【" + jobInfo.getJobName() + "】运行成功！");
//    }
//
//}
